package com.sfang.common.base.topic;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface RabbitmqTopic {
    String HIKVISION_EVENT_INPUT = "hikvisionEventInput";
    String HIKVISION_EVENT_OUTPUT = "hikvisionEventOutput";

    @Input(RabbitmqTopic.HIKVISION_EVENT_INPUT)
    SubscribableChannel hikvisionEventInput();

    @Output(RabbitmqTopic.HIKVISION_EVENT_OUTPUT)
    MessageChannel hikvisionEventOutput();


    String IMS_ALARM_INPUT = "imsAlarmInput";
    String IMS_ALARM_OUTPUT = "imsAlarmOutput";

    @Input(RabbitmqTopic.IMS_ALARM_INPUT)
    SubscribableChannel imsAlarmInput();

    @Output(RabbitmqTopic.IMS_ALARM_OUTPUT)
    MessageChannel imsAlarmOutput();

    String EPR_ALARM_INPUT = "eprAlarmInput";
    String EPR_ALARM_OUTPUT = "eprAlarmOutput";

    @Input(RabbitmqTopic.EPR_ALARM_INPUT)
    SubscribableChannel eprAlarmInput();

    @Output(RabbitmqTopic.EPR_ALARM_OUTPUT)
    MessageChannel eprAlarmOutput();
}
